package com.Reactor3参考文档.condition;

import reactor.core.publisher.Flux;

public class TakeWhile {

	// 断言条件返回true时才进行元素提取
	// 从一个包含100个连续元素的序列中获取1到10的元素
	public static void main(String[] args) {
		Flux.range(1, 100).takeWhile(i -> i <= 10).subscribe(System.out::println);
	}

}
